//package com.mti;
//
//import com.mti.proto.Linksystem;
//import org.springframework.web.reactive.socket.client.ReactorNettyWebSocketClient;
//import org.springframework.web.reactive.socket.client.WebSocketClient;
//import reactor.core.publisher.Flux;
//
//import java.net.URI;
//import java.time.Duration;
//
//public class WSClient {
//
//    public static void main(final String[] args) {
////        Linksystem.LinkLoginReq.Builder login =Linksystem.LinkLoginReq.newBuilder();
////        Linksystem.LinkLoginResp.Builder loginRes = Linksystem.LinkLoginResp.newBuilder();
////        login.setStrPasswd("123456");
////        login.setStrUserName("user");
////        login.setNClientType(1);
////        byte[] bytes = login.build().toByteArray();
////        final WebSocketClient client = new ReactorNettyWebSocketClient();
////        client.execute(URI.create("ws://localhost:8080/echo"), session ->
////                session.send(Flux.just(session.binaryMessage((a) -> a.wrap(bytes))))
////        .doOnNext(d -> d.toString()))
////                .block(Duration.ofMillis(5000));
//
//    }
//}
